
import org.apache.spark.{SparkConf, SparkContext}

object CartesianRDD {
  def main(args: Array[String]): Unit = {
    val conf = new SparkConf().setAppName("CartesianRDD").setMaster("local[*]")
    val sc = new SparkContext(conf)


    val rdd1 = sc.parallelize(List(1, 3, 5, 3))

    val rdd2 = sc.parallelize(List(2, 4, 5, 1))

    val resultRDD = rdd1.cartesian(rdd2)


    println("RDD1 元素：")
    rdd1.collect().foreach(println)
    println("\nRDD2 元素：")
    rdd2.collect().foreach(println)
    println("\n交集结果（自动去重）：")
    resultRDD.collect().foreach(println)

    sc.stop()
  }
}
